package laba3;

import java.io.*;
import java.util.List;
import java.util.LinkedList;
import java.util.Scanner;
import java.util.concurrent.*;
import java.util.Vector;

/**
 * Created by Mikhail on 06.05.14.
 * Sort a set of the integers from the file using a merge sort.
 */
public class Main {
    public static void main(String[] args) throws IOException{
        Scanner in = null;
        FileWriter out = null;

        try {
            //Считать аргументы, открыть файл
            String inFileName = args[0], outFileName = args[1];
            int threadsCount = Integer.parseInt(args[2]);
            in = new Scanner(new BufferedReader(new FileReader(inFileName)));
            out = new FileWriter(outFileName);

            //Считать все строки
            LinkedList<Callable<Vector<Integer>>> strings = new LinkedList<Callable<Vector<Integer>>>();
            while (in.hasNextLine())
                strings.add(new Parser(in.nextLine()));

            //Отправить парситься
            ExecutorService executorService = Executors.newFixedThreadPool(threadsCount);
            List<Future<Vector<Integer>>> results = executorService.invokeAll(strings);

            //Собрать в список отсортированных векторов из одного элемента
            LinkedList<Callable<Vector<Integer>>> numbers = new LinkedList<Callable<Vector<Integer>>>();
            for (Future<Vector<Integer>> res : results) {
                Vector<Integer> vec = res.get();
                for (Integer el : vec) numbers.add(new Sorter(el));
            }

            //Отправить сортироваться
            List<Future<Vector<Integer>>> forSorting = executorService.invokeAll(numbers);
            while (forSorting.size() > 1) {
                numbers.clear();
                int i = 0;
                for (; i < forSorting.size()-1; i+=2)
                {
                    numbers.add(new Sorter(forSorting.get(i).get(),forSorting.get(i+1).get()));
                }
                if (i < forSorting.size()) numbers.add(new Sorter(forSorting.get(i).get()));
                forSorting = executorService.invokeAll(numbers);
            }

            //Вывести отсортированное
            Vector<Integer> sorted = forSorting.get(0).get();
            for (int el : sorted) out.write(el + " ");

        } catch (ArrayIndexOutOfBoundsException e) {
            System.out.println("Неверное количество аргументов:\n" + e.getMessage());
        } catch (NumberFormatException e) {
            System.out.println("Третий аргумент (количество потоков) должен быть целочисленным.\n" + e.getMessage());
        } catch (InterruptedException e) {
            System.out.println("Выполнение было прервано:\n" + e.getMessage());
        } catch (ExecutionException e) {
            System.out.println("Ошибка при выполнении:\n" + e.getMessage());
        } catch (FileNotFoundException  e) {
            System.out.println("Ошибка открытия файла:\n" + e.getMessage());
        } catch (IOException e) {
            System.out.println("Ошибка записи в файл:\n" + e.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (in != null) in.close();
            try {
                if (out != null) out.close();
            } catch (IOException e) {
                System.out.println("Ошибка закрытия файла " + args[1] + ":\n" + e.getMessage());
            }
        }
    }
}
